package io.xiyou.user.listener;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * @ClassName：TopicConsumerListener
 * @Author：西柚
 * @Date：2021/10/28 6:08 下午
 * @Versiion：1.0
 */
@Component
public class TopicConsumerListener {

    //topic模式的消费者
    @JmsListener(destination = "${spring.activemq.topic-name}", containerFactory = "topicListener")
    public void readActiveQueue(String message) {
        System.out.println("topic接收到：" + message);
    }

}
